package com.cimu.activemq.doublequeue;

import com.cimu.activemq.constants.Constants;
import lombok.extern.slf4j.Slf4j;
import org.springframework.jms.annotation.JmsListener;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Component;

/**
 * Title: OneQueueConsumer
 * Copyright: Copyright (c) 2017
 *
 * date 2018年12月09日 13:51
 */
@Component
@Slf4j
public class OneQueueConsumer {

    @JmsListener(destination = Constants.ONE_QUEUE)
    @SendTo(Constants.TWO_QUEUE)
    public String receiveQueue(String text) {
        log.info("===one_queue==={}===========",text);
        //必须返回内容，否则不能发送到下面的队列
        return text;
    }

}
